Modifier and Type | Field and Description |
---|---|
protected boolean |
closed |
Constructor and Description |
---|
JsonObsReader(DownloadJob downloadJob,
String endpoint,
String ak,
String sk,
List<com.obs.services.model.ObsObject> objects) |
JsonObsReader(DownloadJob downloadJob,
String endpoint,
String ak,
String sk,
String bucketName,
String objectPrefix)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
hasNext() |
boolean |
isClosed() |
void |
openReader() |
Row |
read() |
void |
setHasRenameCol(boolean hasRenameCol)
A flag used to determine whether to read JSON data based on the name of c$i.
|
@Deprecated public JsonObsReader(DownloadJob downloadJob, String endpoint, String ak, String sk, String bucketName, String objectPrefix)
public JsonObsReader(DownloadJob downloadJob, String endpoint, String ak, String sk, List<com.obs.services.model.ObsObject> objects)
public void openReader() throws IOException
openReader
in interface Reader
IOException
public Row read() throws DLIException, IOException
read
in interface Reader
DLIException
IOException
public void setHasRenameCol(boolean hasRenameCol)
hasRenameCol
- If rename the column name to c$i when write data.public void close() throws IOException
close
in interface Reader
IOException
Copyright © 2023. All rights reserved.