Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::DataStreamTest Member List

This is the complete list of members for impala::DataStreamTest, including all inherited members.

batch_impala::DataStreamTestprotected
BATCH_CAPACITYimpala::DataStreamTestprotectedstatic
broadcast_sink_impala::DataStreamTestprotected
CheckReceivers(TPartitionType::type stream_type, int num_senders)impala::DataStreamTestinlineprotected
CheckSenders()impala::DataStreamTestinlineprotected
CreateRowBatch()impala::DataStreamTestinlineprotected
CreateRowDesc()impala::DataStreamTestinlineprotected
CreateTupleComparator()impala::DataStreamTestinlineprotected
DataStreamTest()impala::DataStreamTestinlineprotected
desc_tbl_impala::DataStreamTestprotected
dest_impala::DataStreamTestprotected
DEST_NODE_IDimpala::DataStreamTestprotectedstatic
dummy_mem_tracker_impala::DataStreamTestprotected
exec_env_impala::DataStreamTestprotected
GetNextBatch(RowBatch *batch, int *next_val)impala::DataStreamTestinlineprotected
GetNextInstanceId(TUniqueId *instance_id)impala::DataStreamTestinlineprotected
GetSink(TPartitionType::type partition_type)impala::DataStreamTestinlineprotected
hash_sink_impala::DataStreamTestprotected
JoinReceivers()impala::DataStreamTestinlineprotected
JoinSenders()impala::DataStreamTestinlineprotected
less_than_impala::DataStreamTestprotected
lhs_slot_ctx_impala::DataStreamTestprivate
MAX_RECEIVERSimpala::DataStreamTestprotectedstatic
MAX_SENDERSimpala::DataStreamTestprotectedstatic
next_instance_id_impala::DataStreamTestprotected
next_val_impala::DataStreamTestprotected
NUM_BATCHESimpala::DataStreamTestprotectedstatic
obj_pool_impala::DataStreamTestprotected
PER_ROW_DATAimpala::DataStreamTestprotectedstatic
random_sink_impala::DataStreamTestprotected
ReadStream(ReceiverInfo *info)impala::DataStreamTestinlineprotected
ReadStreamMerging(ReceiverInfo *info, RuntimeProfile *profile)impala::DataStreamTestinlineprotected
receiver_info_impala::DataStreamTestprotected
Reset()impala::DataStreamTestinlineprotected
rhs_slot_ctx_impala::DataStreamTestprivate
row_desc_impala::DataStreamTestprotected
runtime_state_impala::DataStreamTestprotected
Sender(int sender_num, int channel_buffer_size, TPartitionType::type partition_type)impala::DataStreamTestinlineprotected
sender_info_impala::DataStreamTestprotected
server_impala::DataStreamTestprotected
SetUp()impala::DataStreamTestinlineprotectedvirtual
StartBackend()impala::DataStreamTestinlineprotected
StartReceiver(TPartitionType::type stream_type, int num_senders, int receiver_num, int buffer_size, bool is_merging, TUniqueId *out_id=NULL)impala::DataStreamTestinlineprotected
StartSender(TPartitionType::type partition_type=TPartitionType::UNPARTITIONED, int channel_buffer_size=1024)impala::DataStreamTestinlineprotected
stmt_impala::DataStreamTestprotected
StopBackend()impala::DataStreamTestinlineprotected
stream_mgr_impala::DataStreamTestprotected
TearDown()impala::DataStreamTestinlineprotectedvirtual
TestStream(TPartitionType::type stream_type, int num_senders, int num_receivers, int buffer_size, bool is_merging)impala::DataStreamTestinlineprotected
TOTAL_DATA_SIZEimpala::DataStreamTestprotectedstatic
tracker_impala::DataStreamTestprotected
tuple_mem_impala::DataStreamTestprotected