public class AvroObsWriter extends Writer
Modifier and Type | Field and Description |
---|---|
protected boolean |
closed |
Constructor and Description |
---|
AvroObsWriter(UploadJob uploadJob,
String endpoint,
String ak,
String sk,
String bucketName,
String objectPrefix) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
flush() |
boolean |
isClosed() |
void |
write(Row row) |
public void write(Row row) throws DLIException
write
in class Writer
DLIException
public void flush() throws DLIException
flush
in class Writer
DLIException
public void close() throws DLIException
close
in class Writer
DLIException
Copyright © 2023. All rights reserved.