public final class ReadingMetadataSpec extends SourceAbilitySpecBase
SourceAbilitySpec
that can not only serialize/deserialize the metadata
columns to/from JSON, but also can read the metadata columns from SupportsReadingMetadata
.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_METADATA_KEYS |
FIELD_NAME_PRODUCED_TYPE
Constructor and Description |
---|
ReadingMetadataSpec(List<String> metadataKeys,
RowType producedType) |
Modifier and Type | Method and Description |
---|---|
void |
apply(DynamicTableSource tableSource,
SourceAbilityContext context)
Apply the ability to the given
DynamicTableSource . |
boolean |
equals(Object o) |
String |
getDigests(SourceAbilityContext context)
Additional digests to generate when this spec is applied to the source.
|
List<String> |
getMetadataKeys() |
int |
hashCode() |
boolean |
needAdjustFieldReferenceAfterProjection()
Does this spec needs adjust field reference after projection.
|
getProducedType
public static final String FIELD_NAME_METADATA_KEYS
public void apply(DynamicTableSource tableSource, SourceAbilityContext context)
SourceAbilitySpec
DynamicTableSource
.public boolean needAdjustFieldReferenceAfterProjection()
SourceAbilitySpec
RexNode
or references fields in scan table, the referenced field indices maybe changed after
projection pushdown with scan reuse. Under such case, this method need to return true to
notify planner doesn't reuse the scan.public String getDigests(SourceAbilityContext context)
SourceAbilitySpec
context
- The context about the source.public boolean equals(Object o)
equals
in class SourceAbilitySpecBase
public int hashCode()
hashCode
in class SourceAbilitySpecBase
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.