def get_es_spark_connector_input_options()

in python/dataproc_templates/util/template_constants.py [0:0]

• 49 lines of code
• 2 McCabe index (conditional complexity)

def get_es_spark_connector_input_options(prefix):
    input_options = [
        ES_NODES_PATH_PREFIX,
        ES_QUERY,
        ES_MAPPING_DATE_RICH,
        ES_READ_FIELD_INCLUDE,
        ES_READ_FIELD_EXCLUDE,
        ES_READ_FIELD_AS_ARRAY_INCLUDE,
        ES_READ_FIELD_AS_ARRAY_EXCLUDE,
        ES_READ_METADATA,
        ES_READ_METADATA_FIELD,
        ES_READ_METADATA_VERSION,
        ES_INDEX_READ_MISSING_AS_EMPTY,
        ES_FIELD_READ_EMPTY_AS_NULL,
        ES_READ_SHARD_PREFERENCE,
        ES_READ_SOURCE_FILTER,
        ES_INDEX_READ_ALLOW_RED_STATUS,
        ES_INPUT_MAX_DOC_PER_PARTITION,
        ES_NODES_DISCOVERY,
        ES_NODES_CLIENT_ONLY,
        ES_NODES_DATA_ONLY,
        ES_NODES_WAN_ONLY,
        ES_HTTP_TIMEOUT,
        ES_HTTP_RETRIES,
        ES_SCROLL_KEEPALIVE,
        ES_SCROLL_SIZE,
        ES_SCROLL_LIMIT,
        ES_ACTION_HEART_BEAT_LEAD,
        ES_NET_SSL,
        ES_NET_SSL_CERT_ALLOW_SELF_SIGNED,
        ES_NET_SSL_PROTOCOL,
        ES_NET_PROXY_HTTP_HOST,
        ES_NET_PROXY_HTTP_PORT,
        ES_NET_PROXY_HTTP_USER,
        ES_NET_PROXY_HTTP_PASS,
        ES_NET_PROXY_HTTP_USE_SYSTEM_PROPS,
        ES_NET_PROXY_HTTPS_HOST,
        ES_NET_PROXY_HTTPS_PORT,
        ES_NET_PROXY_HTTPS_USER,
        ES_NET_PROXY_HTTPS_PASS,
        ES_NET_PROXY_HTTPS_USE_SYSTEM_PROPS,
        ES_NET_PROXY_SOCKS_HOST,
        ES_NET_PROXY_SOCKS_PORT,
        ES_NET_PROXY_SOCKS_USER,
        ES_NET_PROXY_SOCKS_PASS,
        ES_NET_PROXY_SOCKS_USE_SYSTEM_PROPS,
    ]
    es_spark_connector_options = {(prefix + _).lower(): _ for _ in input_options}
    return es_spark_connector_options