This is the complete list of members for impala::DataStreamTest, including all inherited members.
batch_ | impala::DataStreamTest | protected |
BATCH_CAPACITY | impala::DataStreamTest | protectedstatic |
broadcast_sink_ | impala::DataStreamTest | protected |
CheckReceivers(TPartitionType::type stream_type, int num_senders) | impala::DataStreamTest | inlineprotected |
CheckSenders() | impala::DataStreamTest | inlineprotected |
CreateRowBatch() | impala::DataStreamTest | inlineprotected |
CreateRowDesc() | impala::DataStreamTest | inlineprotected |
CreateTupleComparator() | impala::DataStreamTest | inlineprotected |
DataStreamTest() | impala::DataStreamTest | inlineprotected |
desc_tbl_ | impala::DataStreamTest | protected |
dest_ | impala::DataStreamTest | protected |
DEST_NODE_ID | impala::DataStreamTest | protectedstatic |
dummy_mem_tracker_ | impala::DataStreamTest | protected |
exec_env_ | impala::DataStreamTest | protected |
GetNextBatch(RowBatch *batch, int *next_val) | impala::DataStreamTest | inlineprotected |
GetNextInstanceId(TUniqueId *instance_id) | impala::DataStreamTest | inlineprotected |
GetSink(TPartitionType::type partition_type) | impala::DataStreamTest | inlineprotected |
hash_sink_ | impala::DataStreamTest | protected |
JoinReceivers() | impala::DataStreamTest | inlineprotected |
JoinSenders() | impala::DataStreamTest | inlineprotected |
less_than_ | impala::DataStreamTest | protected |
lhs_slot_ctx_ | impala::DataStreamTest | private |
MAX_RECEIVERS | impala::DataStreamTest | protectedstatic |
MAX_SENDERS | impala::DataStreamTest | protectedstatic |
next_instance_id_ | impala::DataStreamTest | protected |
next_val_ | impala::DataStreamTest | protected |
NUM_BATCHES | impala::DataStreamTest | protectedstatic |
obj_pool_ | impala::DataStreamTest | protected |
PER_ROW_DATA | impala::DataStreamTest | protectedstatic |
random_sink_ | impala::DataStreamTest | protected |
ReadStream(ReceiverInfo *info) | impala::DataStreamTest | inlineprotected |
ReadStreamMerging(ReceiverInfo *info, RuntimeProfile *profile) | impala::DataStreamTest | inlineprotected |
receiver_info_ | impala::DataStreamTest | protected |
Reset() | impala::DataStreamTest | inlineprotected |
rhs_slot_ctx_ | impala::DataStreamTest | private |
row_desc_ | impala::DataStreamTest | protected |
runtime_state_ | impala::DataStreamTest | protected |
Sender(int sender_num, int channel_buffer_size, TPartitionType::type partition_type) | impala::DataStreamTest | inlineprotected |
sender_info_ | impala::DataStreamTest | protected |
server_ | impala::DataStreamTest | protected |
SetUp() | impala::DataStreamTest | inlineprotectedvirtual |
StartBackend() | impala::DataStreamTest | inlineprotected |
StartReceiver(TPartitionType::type stream_type, int num_senders, int receiver_num, int buffer_size, bool is_merging, TUniqueId *out_id=NULL) | impala::DataStreamTest | inlineprotected |
StartSender(TPartitionType::type partition_type=TPartitionType::UNPARTITIONED, int channel_buffer_size=1024) | impala::DataStreamTest | inlineprotected |
stmt_ | impala::DataStreamTest | protected |
StopBackend() | impala::DataStreamTest | inlineprotected |
stream_mgr_ | impala::DataStreamTest | protected |
TearDown() | impala::DataStreamTest | inlineprotectedvirtual |
TestStream(TPartitionType::type stream_type, int num_senders, int num_receivers, int buffer_size, bool is_merging) | impala::DataStreamTest | inlineprotected |
TOTAL_DATA_SIZE | impala::DataStreamTest | protectedstatic |
tracker_ | impala::DataStreamTest | protected |
tuple_mem_ | impala::DataStreamTest | protected |