...
Code Block |
---|
public class TableSinkConfig extends PluginConfig {
@Name(Properties.Table.NAME)
@Description("Name of the table. If the table does not already exist, one will be created.")
// The name of the table can be specified by a runtime macro, by default macros are disabled for fields.
this field uses the value "test" at config time.
@Macro(enabled=true)
private String name;
@Name(Properties.Table.PROPERTY_SCHEMA)
@Description("schema of the table as a JSON Object. If the table does not already exist, one will be " +
"created with this schema, which will allow the table to be explored through Hive. If no schema is given, the " +
"table created will not be explorable.")
@Nullable
private String schemaStr;
@Name(Properties.Table.PROPERTY_SCHEMA_ROW_FIELD)
@Description("The name of the record field that should be used as the row key when writing to the table.")
private String rowField;
} |
...