public abstract class TunnelJob extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TunnelJob.FileFormat |
Modifier and Type | Field and Description |
---|---|
protected String |
bucketName |
protected String |
nullValue |
protected String |
objectPrefix |
protected List<Column> |
partCols |
protected TableSchema |
tblSchema |
Constructor and Description |
---|
TunnelJob() |
Modifier and Type | Method and Description |
---|---|
Row |
newRow() |
protected void |
prepare(Queue queue,
String dbName,
String tblName,
String opType) |
protected void |
prepare(Queue queue,
TableSchema tblSchema) |
protected boolean |
validPartSpec(PartitionSpec partSpec) |
protected String bucketName
protected String objectPrefix
protected TableSchema tblSchema
protected String nullValue
protected void prepare(Queue queue, String dbName, String tblName, String opType) throws DLIException
DLIException
protected void prepare(Queue queue, TableSchema tblSchema) throws DLIException
DLIException
protected boolean validPartSpec(PartitionSpec partSpec)
public Row newRow()
Copyright © 2023. All rights reserved.