Package | Description |
---|---|
org.apache.drill.exec.store.iceberg | |
org.apache.drill.exec.store.iceberg.read |
Modifier and Type | Method and Description |
---|---|
IcebergWork |
IcebergWork.IcebergWorkDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser p,
com.fasterxml.jackson.databind.DeserializationContext ctxt) |
Modifier and Type | Method and Description |
---|---|
List<IcebergWork> |
IcebergSubScan.getWorkList() |
Modifier and Type | Method and Description |
---|---|
void |
IcebergWork.IcebergWorkSerializer.serialize(IcebergWork value,
com.fasterxml.jackson.core.JsonGenerator gen,
com.fasterxml.jackson.databind.SerializerProvider provider) |
Modifier and Type | Method and Description |
---|---|
IcebergSubScan.IcebergSubScanBuilder |
IcebergSubScan.IcebergSubScanBuilder.workList(List<IcebergWork> workList) |
Constructor and Description |
---|
IcebergSubScan(String userName,
StoragePluginConfig storageConfig,
FormatPluginConfig formatConfig,
List<SchemaPath> columns,
String path,
List<IcebergWork> workList,
TupleMetadata schema,
LogicalExpression condition,
Integer maxRecords,
StoragePluginRegistry pluginRegistry) |
Constructor and Description |
---|
IcebergRecordReader(org.apache.iceberg.TableScan tableScan,
IcebergWork work,
int maxRecords) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.