public static class SpannerTransformRegistrar.ReadBuilder.Configuration extends SpannerTransformRegistrar.CrossLanguageConfiguration
Constructor and Description |
---|
Configuration() |
Modifier and Type | Method and Description |
---|---|
ReadOperation |
getReadOperation() |
void |
setBatching(@Nullable java.lang.Boolean batching) |
void |
setReadTimestamp(@Nullable java.lang.String readTimestamp) |
void |
setSchema(byte[] schema) |
void |
setSql(@Nullable java.lang.String sql) |
void |
setStaleness(@Nullable java.lang.Long staleness) |
void |
setTable(@Nullable java.lang.String table) |
void |
setTimestampBoundMode(@Nullable java.lang.String timestampBoundMode) |
void |
setTimeUnit(@Nullable java.lang.String timeUnit) |
setDatabaseId, setEmulatorHost, setHost, setInstanceId, setProjectId
public void setSql(@Nullable java.lang.String sql)
public void setTable(@Nullable java.lang.String table)
public void setBatching(@Nullable java.lang.Boolean batching)
public void setTimestampBoundMode(@Nullable java.lang.String timestampBoundMode)
public void setSchema(byte[] schema) throws org.apache.beam.vendor.grpc.v1p48p1.com.google.protobuf.InvalidProtocolBufferException
org.apache.beam.vendor.grpc.v1p48p1.com.google.protobuf.InvalidProtocolBufferException
public void setReadTimestamp(@Nullable java.lang.String readTimestamp)
public void setTimeUnit(@Nullable java.lang.String timeUnit)
public void setStaleness(@Nullable java.lang.Long staleness)
public ReadOperation getReadOperation()