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 |