Package com.here.platform.data.client.flink.common

Class Properties

java.lang.Object
com.here.platform.data.client.flink.common.Properties
public class Properties extends Object

  • Constructor Details

    • Properties

      public Properties()

  • Method Details

    • CONTINUOUS_VERSION_LAYER_DEFAULT

      public static boolean CONTINUOUS_VERSION_LAYER_DEFAULT()

    • READ_BLOB_BATCH_SIZE_DEFAULT

      public static int READ_BLOB_BATCH_SIZE_DEFAULT()

    • READ_BLOB_TIMEOUT_DEFAULT

      public static int READ_BLOB_TIMEOUT_DEFAULT()

    • WRITE_BLOB_BATCH_SIZE_DEFAULT

      public static int WRITE_BLOB_BATCH_SIZE_DEFAULT()

    • WRITE_BLOB_TIMEOUT_DEFAULT

      public static int WRITE_BLOB_TIMEOUT_DEFAULT()

    • IGNORE_INVALID_PARTITIONS_DEFAULT

      public static boolean IGNORE_INVALID_PARTITIONS_DEFAULT()

    • READ_INTERACTIVEMAP_PARALLELISM_DEFAULT

      public static int READ_INTERACTIVEMAP_PARALLELISM_DEFAULT()

    • READ_INTERACTIVEMAP_MAX_FEATURES_PER_REQUEST_DEFAULT

      public static int READ_INTERACTIVEMAP_MAX_FEATURES_PER_REQUEST_DEFAULT()

    • READ_INTERACTIVEMAP_TIMEOUT_DEFAULT

      public static long READ_INTERACTIVEMAP_TIMEOUT_DEFAULT()

    • WRITE_INTERACTIVEMAP_PARALLELISM_DEFAULT

      public static int WRITE_INTERACTIVEMAP_PARALLELISM_DEFAULT()

    • WRITE_INTERACTIVEMAP_TIMEOUT_DEFAULT

      public static long WRITE_INTERACTIVEMAP_TIMEOUT_DEFAULT()

    • AGGREGATION_INTERVAL_DEFAULT

      public static long AGGREGATION_INTERVAL_DEFAULT()

    • BATCH_INTERVAL_DEFAULT

      public static long BATCH_INTERVAL_DEFAULT()

    • LAYER_REFRESH_INTERVAL_DEFAULT

      public static long LAYER_REFRESH_INTERVAL_DEFAULT()

    • MAX_PARALLEL_BATCHES_DEFAULT

      public static int MAX_PARALLEL_BATCHES_DEFAULT()

    • OFFSET_PROPERTY_LATEST_VALUE

      public static String OFFSET_PROPERTY_LATEST_VALUE()

    • OFFSET_PROPERTY_EARLIEST_VALUE

      public static String OFFSET_PROPERTY_EARLIEST_VALUE()

    • HRN_PROPERTY

      public static org.apache.flink.configuration.ConfigOption<String> HRN_PROPERTY()

    • LAYER_ID_PROPERTY

      public static org.apache.flink.configuration.ConfigOption<String> LAYER_ID_PROPERTY()

    • SCHEMA_PROPERTY

      public static org.apache.flink.configuration.ConfigOption<String> SCHEMA_PROPERTY()

    • QUERY_STRING

      public static org.apache.flink.configuration.ConfigOptions.TypedConfigOptionBuilder<String> QUERY_STRING()

    • QUERY_PARALLELISM

      public static org.apache.flink.configuration.ConfigOption<Integer> QUERY_PARALLELISM()

    • AGGREGATION_INTERVAL

      public static org.apache.flink.configuration.ConfigOption<Long> AGGREGATION_INTERVAL()

    • BATCH_INTERVAL

      public static org.apache.flink.configuration.ConfigOption<Long> BATCH_INTERVAL()

    • MAX_PARALLEL_BATCHES

      public static org.apache.flink.configuration.ConfigOption<Integer> MAX_PARALLEL_BATCHES()

    • LAYER_REFRESH_INTERVAL

      public static org.apache.flink.configuration.ConfigOption<Long> LAYER_REFRESH_INTERVAL()

    • FORCE_RAW_DATA

      public static org.apache.flink.configuration.ConfigOption<Boolean> FORCE_RAW_DATA()

    • GROUP_NAME_PROPERTY

      public static org.apache.flink.configuration.ConfigOption<String> GROUP_NAME_PROPERTY()

    • OFFSET_PROPERTY

      public static org.apache.flink.configuration.ConfigOption<String> OFFSET_PROPERTY()

    • CONNECTOR_MODE

      public static org.apache.flink.configuration.ConfigOption<String> CONNECTOR_MODE()

    • IGNORE_INVALID_PARTITIONS

      public static org.apache.flink.configuration.ConfigOption<Boolean> IGNORE_INVALID_PARTITIONS()

    • READ_BLOB_BATCH_SIZE

      public static org.apache.flink.configuration.ConfigOption<Integer> READ_BLOB_BATCH_SIZE()

    • READ_BLOB_TIMEOUT

      public static org.apache.flink.configuration.ConfigOption<Long> READ_BLOB_TIMEOUT()

    • READ_INTERACTIVEMAP_PARALLELISM

      public static org.apache.flink.configuration.ConfigOption<Integer> READ_INTERACTIVEMAP_PARALLELISM()

    • READ_INTERACTIVEMAP_MAX_FEATURES_PER_REQUEST

      public static org.apache.flink.configuration.ConfigOption<Integer> READ_INTERACTIVEMAP_MAX_FEATURES_PER_REQUEST()

    • READ_INTERACTIVEMAP_TIMEOUT

      public static org.apache.flink.configuration.ConfigOption<Long> READ_INTERACTIVEMAP_TIMEOUT()

    • WRITE_BLOB_BATCH_SIZE

      public static org.apache.flink.configuration.ConfigOption<Integer> WRITE_BLOB_BATCH_SIZE()

    • WRITE_BLOB_TIMEOUT

      public static org.apache.flink.configuration.ConfigOption<Long> WRITE_BLOB_TIMEOUT()

    • WRITE_INTERACTIVEMAP_PARALLELISM

      public static org.apache.flink.configuration.ConfigOption<Integer> WRITE_INTERACTIVEMAP_PARALLELISM()

    • WRITE_INTERACTIVEMAP_TIMEOUT

      public static org.apache.flink.configuration.ConfigOption<Long> WRITE_INTERACTIVEMAP_TIMEOUT()

    • METADATA_COLUMNS

      public static org.apache.flink.configuration.ConfigOption<Boolean> METADATA_COLUMNS()

    • SCHEMA_NAME

      public static org.apache.flink.configuration.ConfigOption<String> SCHEMA_NAME()

    • SCHEMA_DATA_TYPE

      public static org.apache.flink.configuration.ConfigOption<String> SCHEMA_DATA_TYPE()

    • UPDATE_MODE

      public static org.apache.flink.configuration.ConfigOption<String> UPDATE_MODE()