org.apache.drill.exec.server.rest.profile

Enum CoreOperatorType

java.lang.Object

java.lang.Enum<CoreOperatorType>

org.apache.drill.exec.server.rest.profile.CoreOperatorType

All Implemented Interfaces:

Serializable, Comparable<CoreOperatorType>

public enum CoreOperatorType
extends Enum<CoreOperatorType>

This class is used for backward compatibility when reading older query profiles that stored operator id instead of its name. Please do not update this class. It will be removed for Drill 2.0

Enum Constant Summary

Enum Constants

Enum Constant and Description
AVRO_SUB_SCAN AVRO_SUB_SCAN = 36;
BROADCAST_SENDER BROADCAST_SENDER = 1;
COMPLEX_TO_JSON COMPLEX_TO_JSON = 31;
DIRECT_SUB_SCAN DIRECT_SUB_SCAN = 26;
DRUID_SUB_SCAN DRUID_SUB_SCAN = 68;
EXCEL_SUB_SCAN EXCEL_SUB_SCAN = 64;
EXTERNAL_SORT EXTERNAL_SORT = 17;
FILTER FILTER = 2;
FLATTEN FLATTEN = 40;
HASH_AGGREGATE HASH_AGGREGATE = 3;
HASH_JOIN HASH_JOIN = 4;
HASH_PARTITION_SENDER HASH_PARTITION_SENDER = 6;
HBASE_SUB_SCAN HBASE_SUB_SCAN = 33;
HDF5_SUB_SCAN HDF5_SUB_SCAN = 63;
HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;
HIVE_SUB_SCAN HIVE_SUB_SCAN = 22;
HTPPD_LOG_SUB_SCAN HTPPD_LOG_SUB_SCAN = 51;
HTTP_SUB_SCAN HTTP_SUB_SCAN = 70;
IMAGE_SUB_SCAN IMAGE_SUB_SCAN = 52;
INFO_SCHEMA_SUB_SCAN INFO_SCHEMA_SUB_SCAN = 30;
JDBC_SCAN JDBC_SCAN = 44;
JSON_SUB_SCAN JSON_SUB_SCAN = 29;
JSON_WRITER JSON_WRITER = 50;
KAFKA_SUB_SCAN KAFKA_SUB_SCAN = 38;
KUDU_SUB_SCAN KUDU_SUB_SCAN = 39;
KUDU_WRITER KUDU_WRITER = 48;
LATERAL_JOIN LATERAL_JOIN = 41;
LIMIT LIMIT = 7;
LTSV_SUB_SCAN LTSV_SUB_SCAN = 62;
MAPRDB_SUB_SCAN MAPRDB_SUB_SCAN = 46;
MERGE_JOIN MERGE_JOIN = 5;
MERGING_RECEIVER MERGING_RECEIVER = 8;
METADATA_CONTROLLER METADATA_CONTROLLER = 67;
METADATA_HANDLER METADATA_HANDLER = 66;
MOCK_SUB_SCAN MOCK_SUB_SCAN = 24;
MONGO_SUB_SCAN MONGO_SUB_SCAN = 47;
NESTED_LOOP_JOIN NESTED_LOOP_JOIN = 35;
OLD_SORT OLD_SORT = 20;
OPEN_TSDB_SUB_SCAN OPEN_TSDB_SUB_SCAN = 49;
ORDERED_PARTITION_SENDER ORDERED_PARTITION_SENDER = 9;
PARQUET_ROW_GROUP_SCAN PARQUET_ROW_GROUP_SCAN = 21;
PARQUET_WRITER PARQUET_WRITER = 25;
PARTITION_LIMIT PARTITION_LIMIT = 54;
PCAP_SUB_SCAN PCAP_SUB_SCAN = 37;
PCAPNG_SUB_SCAN PCAPNG_SUB_SCAN = 55;
PRODUCER_CONSUMER PRODUCER_CONSUMER = 32;
PROJECT PROJECT = 10;
RANGE_PARTITION_SENDER RANGE_PARTITION_SENDER = 12;
REGEX_SUB_SCAN REGEX_SUB_SCAN = 45;
ROWKEY_JOIN ROWKEY_JOIN = 57;
RUNTIME_FILTER RUNTIME_FILTER = 56;
SCREEN SCREEN = 13;
SELECTION_VECTOR_REMOVER SELECTION_VECTOR_REMOVER = 14;
SEQUENCE_SUB_SCAN SEQUENCE_SUB_SCAN = 53;
SHP_SUB_SCAN SHP_SUB_SCAN = 65;
SINGLE_SENDER SINGLE_SENDER = 0;
SPSS_SUB_SCAN SPSS_SUB_SCAN = 69;
STATISTICS_AGGREGATE STATISTICS_AGGREGATE = 59;
STATISTICS_MERGE STATISTICS_MERGE = 61;
STREAMING_AGGREGATE STREAMING_AGGREGATE = 15;
SYSLOG_SUB_SCAN SYSLOG_SUB_SCAN = 58;
SYSTEM_TABLE_SCAN SYSTEM_TABLE_SCAN = 23;
TEXT_SUB_SCAN TEXT_SUB_SCAN = 28;
TEXT_WRITER TEXT_WRITER = 27;
TOP_N_SORT TOP_N_SORT = 16;
TRACE TRACE = 18;
UNION UNION = 19;
UNNEST UNNEST = 42;
UNORDERED_RECEIVER UNORDERED_RECEIVER = 11;
UNPIVOT_MAPS UNPIVOT_MAPS = 60;
WINDOW WINDOW = 34;
XML_SUB_SCAN XML_SUB_SCAN = 71;

Method Summary

Modifier and Type	Method and Description
static CoreOperatorType	forName(String name)
int	getId()
static CoreOperatorType	valueOf(int id)
static CoreOperatorType	valueOf(String name) Returns the enum constant of this type with the specified name.
static CoreOperatorType[]	values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

SINGLE_SENDER

public static final CoreOperatorType SINGLE_SENDER

SINGLE_SENDER = 0;

BROADCAST_SENDER

public static final CoreOperatorType BROADCAST_SENDER

BROADCAST_SENDER = 1;

FILTER

public static final CoreOperatorType FILTER

FILTER = 2;

HASH_AGGREGATE

public static final CoreOperatorType HASH_AGGREGATE

HASH_AGGREGATE = 3;

HASH_JOIN

public static final CoreOperatorType HASH_JOIN

HASH_JOIN = 4;

MERGE_JOIN

public static final CoreOperatorType MERGE_JOIN

MERGE_JOIN = 5;

HASH_PARTITION_SENDER

public static final CoreOperatorType HASH_PARTITION_SENDER

HASH_PARTITION_SENDER = 6;

LIMIT

public static final CoreOperatorType LIMIT

LIMIT = 7;

MERGING_RECEIVER

public static final CoreOperatorType MERGING_RECEIVER

MERGING_RECEIVER = 8;

ORDERED_PARTITION_SENDER

public static final CoreOperatorType ORDERED_PARTITION_SENDER

ORDERED_PARTITION_SENDER = 9;

PROJECT

public static final CoreOperatorType PROJECT

PROJECT = 10;

UNORDERED_RECEIVER

public static final CoreOperatorType UNORDERED_RECEIVER

UNORDERED_RECEIVER = 11;

RANGE_PARTITION_SENDER

public static final CoreOperatorType RANGE_PARTITION_SENDER

RANGE_PARTITION_SENDER = 12;

SCREEN

public static final CoreOperatorType SCREEN

SCREEN = 13;

SELECTION_VECTOR_REMOVER

public static final CoreOperatorType SELECTION_VECTOR_REMOVER

SELECTION_VECTOR_REMOVER = 14;

STREAMING_AGGREGATE

public static final CoreOperatorType STREAMING_AGGREGATE

STREAMING_AGGREGATE = 15;

TOP_N_SORT

public static final CoreOperatorType TOP_N_SORT

TOP_N_SORT = 16;

EXTERNAL_SORT

public static final CoreOperatorType EXTERNAL_SORT

EXTERNAL_SORT = 17;

TRACE

public static final CoreOperatorType TRACE

TRACE = 18;

UNION

public static final CoreOperatorType UNION

UNION = 19;

OLD_SORT

public static final CoreOperatorType OLD_SORT

OLD_SORT = 20;

PARQUET_ROW_GROUP_SCAN

public static final CoreOperatorType PARQUET_ROW_GROUP_SCAN

PARQUET_ROW_GROUP_SCAN = 21;

HIVE_SUB_SCAN

public static final CoreOperatorType HIVE_SUB_SCAN

HIVE_SUB_SCAN = 22;

SYSTEM_TABLE_SCAN

public static final CoreOperatorType SYSTEM_TABLE_SCAN

SYSTEM_TABLE_SCAN = 23;

MOCK_SUB_SCAN

public static final CoreOperatorType MOCK_SUB_SCAN

MOCK_SUB_SCAN = 24;

PARQUET_WRITER

public static final CoreOperatorType PARQUET_WRITER

PARQUET_WRITER = 25;

DIRECT_SUB_SCAN

public static final CoreOperatorType DIRECT_SUB_SCAN

DIRECT_SUB_SCAN = 26;

TEXT_WRITER

public static final CoreOperatorType TEXT_WRITER

TEXT_WRITER = 27;

TEXT_SUB_SCAN

public static final CoreOperatorType TEXT_SUB_SCAN

TEXT_SUB_SCAN = 28;

JSON_SUB_SCAN

public static final CoreOperatorType JSON_SUB_SCAN

JSON_SUB_SCAN = 29;

INFO_SCHEMA_SUB_SCAN

public static final CoreOperatorType INFO_SCHEMA_SUB_SCAN

INFO_SCHEMA_SUB_SCAN = 30;

COMPLEX_TO_JSON

public static final CoreOperatorType COMPLEX_TO_JSON

COMPLEX_TO_JSON = 31;

PRODUCER_CONSUMER

public static final CoreOperatorType PRODUCER_CONSUMER

PRODUCER_CONSUMER = 32;

HBASE_SUB_SCAN

public static final CoreOperatorType HBASE_SUB_SCAN

HBASE_SUB_SCAN = 33;

WINDOW

public static final CoreOperatorType WINDOW

WINDOW = 34;

NESTED_LOOP_JOIN

public static final CoreOperatorType NESTED_LOOP_JOIN

NESTED_LOOP_JOIN = 35;

AVRO_SUB_SCAN

public static final CoreOperatorType AVRO_SUB_SCAN

AVRO_SUB_SCAN = 36;

PCAP_SUB_SCAN

public static final CoreOperatorType PCAP_SUB_SCAN

PCAP_SUB_SCAN = 37;

KAFKA_SUB_SCAN

public static final CoreOperatorType KAFKA_SUB_SCAN

KAFKA_SUB_SCAN = 38;

KUDU_SUB_SCAN

public static final CoreOperatorType KUDU_SUB_SCAN

KUDU_SUB_SCAN = 39;

FLATTEN

public static final CoreOperatorType FLATTEN

FLATTEN = 40;

LATERAL_JOIN

public static final CoreOperatorType LATERAL_JOIN

LATERAL_JOIN = 41;

UNNEST

public static final CoreOperatorType UNNEST

UNNEST = 42;

HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN

public static final CoreOperatorType HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN

HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;

JDBC_SCAN

public static final CoreOperatorType JDBC_SCAN

JDBC_SCAN = 44;

REGEX_SUB_SCAN

public static final CoreOperatorType REGEX_SUB_SCAN

REGEX_SUB_SCAN = 45;

MAPRDB_SUB_SCAN

public static final CoreOperatorType MAPRDB_SUB_SCAN

MAPRDB_SUB_SCAN = 46;

MONGO_SUB_SCAN

public static final CoreOperatorType MONGO_SUB_SCAN

MONGO_SUB_SCAN = 47;

KUDU_WRITER

public static final CoreOperatorType KUDU_WRITER

KUDU_WRITER = 48;

OPEN_TSDB_SUB_SCAN

public static final CoreOperatorType OPEN_TSDB_SUB_SCAN

OPEN_TSDB_SUB_SCAN = 49;

JSON_WRITER

public static final CoreOperatorType JSON_WRITER

JSON_WRITER = 50;

HTPPD_LOG_SUB_SCAN

public static final CoreOperatorType HTPPD_LOG_SUB_SCAN

HTPPD_LOG_SUB_SCAN = 51;

IMAGE_SUB_SCAN

public static final CoreOperatorType IMAGE_SUB_SCAN

IMAGE_SUB_SCAN = 52;

SEQUENCE_SUB_SCAN

public static final CoreOperatorType SEQUENCE_SUB_SCAN

SEQUENCE_SUB_SCAN = 53;

PARTITION_LIMIT

public static final CoreOperatorType PARTITION_LIMIT

PARTITION_LIMIT = 54;

PCAPNG_SUB_SCAN

public static final CoreOperatorType PCAPNG_SUB_SCAN

PCAPNG_SUB_SCAN = 55;

RUNTIME_FILTER

public static final CoreOperatorType RUNTIME_FILTER

RUNTIME_FILTER = 56;

ROWKEY_JOIN

public static final CoreOperatorType ROWKEY_JOIN

ROWKEY_JOIN = 57;

SYSLOG_SUB_SCAN

public static final CoreOperatorType SYSLOG_SUB_SCAN

SYSLOG_SUB_SCAN = 58;

STATISTICS_AGGREGATE

public static final CoreOperatorType STATISTICS_AGGREGATE

STATISTICS_AGGREGATE = 59;

UNPIVOT_MAPS

public static final CoreOperatorType UNPIVOT_MAPS

UNPIVOT_MAPS = 60;

STATISTICS_MERGE

public static final CoreOperatorType STATISTICS_MERGE

STATISTICS_MERGE = 61;

LTSV_SUB_SCAN

public static final CoreOperatorType LTSV_SUB_SCAN

LTSV_SUB_SCAN = 62;

HDF5_SUB_SCAN

public static final CoreOperatorType HDF5_SUB_SCAN

HDF5_SUB_SCAN = 63;

EXCEL_SUB_SCAN

public static final CoreOperatorType EXCEL_SUB_SCAN

EXCEL_SUB_SCAN = 64;

SHP_SUB_SCAN

public static final CoreOperatorType SHP_SUB_SCAN

SHP_SUB_SCAN = 65;

METADATA_HANDLER

public static final CoreOperatorType METADATA_HANDLER

METADATA_HANDLER = 66;

METADATA_CONTROLLER

public static final CoreOperatorType METADATA_CONTROLLER

METADATA_CONTROLLER = 67;

DRUID_SUB_SCAN

public static final CoreOperatorType DRUID_SUB_SCAN

DRUID_SUB_SCAN = 68;

SPSS_SUB_SCAN

public static final CoreOperatorType SPSS_SUB_SCAN

SPSS_SUB_SCAN = 69;

HTTP_SUB_SCAN

public static final CoreOperatorType HTTP_SUB_SCAN

HTTP_SUB_SCAN = 70;

XML_SUB_SCAN

public static final CoreOperatorType XML_SUB_SCAN

XML_SUB_SCAN = 71;

Method Detail

values

public static CoreOperatorType[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (CoreOperatorType c : CoreOperatorType.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static CoreOperatorType valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null

getId

public int getId()

valueOf

public static CoreOperatorType valueOf(int id)

forName

public static CoreOperatorType forName(String name)