Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BIGQUERY_JOB_TEMPLATE |
"beam_bq_job_{TYPE}_{JOB_ID}_{STEP}_{RANDOM}" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COLUMNS_MAPPING |
"columnsMapping" |
public static final java.lang.String |
KEY |
"key" |
public static final java.lang.String |
LABELS |
"labels" |
public static final java.lang.String |
TIMESTAMP_MICROS |
"timestampMicros" |
public static final java.lang.String |
VALUE |
"val" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_QUERY_SPLITS_MAX |
50000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KEY_FIELD_PROPERTY |
"keyField" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TIMESTAMP_FIELD_NAME |
"observed_time" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:external:java:pubsub:read:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:external:java:pubsub:write:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_ATTRIBUTE |
"x-goog-pubsublite-dataflow-uuid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_HASH_PARTITIONS |
10000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DELETE_URN |
"beam:external:java:spanner:delete:v1" |
public static final java.lang.String |
INSERT_OR_UPDATE_URN |
"beam:external:java:spanner:insert_or_update:v1" |
public static final java.lang.String |
INSERT_URN |
"beam:external:java:spanner:insert:v1" |
public static final java.lang.String |
READ_URN |
"beam:external:java:spanner:read:v1" |
public static final java.lang.String |
REPLACE_URN |
"beam:external:java:spanner:replace:v1" |
public static final java.lang.String |
UPDATE_URN |
"beam:external:java:spanner:update:v1" |