Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Member Functions | Public Attributes | List of all members
impala::DataStreamTest::ReceiverInfo Struct Reference
Collaboration diagram for impala::DataStreamTest::ReceiverInfo:

Public Member Functions

 ReceiverInfo (TPartitionType::type stream_type, int num_senders, int receiver_num)
 
 ~ReceiverInfo ()
 

Public Attributes

TPartitionType::type stream_type
 
int num_senders
 
int receiver_num
 
thread * thread_handle
 
shared_ptr< DataStreamRecvr > stream_recvr
 
Status status
 
int num_rows_received
 
multiset< int64_t > data_values
 

Detailed Description

Definition at line 207 of file data-stream-test.cc.

Constructor & Destructor Documentation

impala::DataStreamTest::ReceiverInfo::ReceiverInfo ( TPartitionType::type  stream_type,
int  num_senders,
int  receiver_num 
)
inline

Definition at line 218 of file data-stream-test.cc.

impala::DataStreamTest::ReceiverInfo::~ReceiverInfo ( )
inline

Definition at line 225 of file data-stream-test.cc.

Member Data Documentation

multiset<int64_t> impala::DataStreamTest::ReceiverInfo::data_values

Definition at line 216 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::CheckReceivers(), impala::DataStreamTest::ReadStream(), and impala::DataStreamTest::ReadStreamMerging().

int impala::DataStreamTest::ReceiverInfo::num_rows_received

Definition at line 215 of file data-stream-test.cc.

int impala::DataStreamTest::ReceiverInfo::num_senders

Definition at line 209 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::CheckReceivers().

int impala::DataStreamTest::ReceiverInfo::receiver_num

Definition at line 210 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::CheckReceivers().

Status impala::DataStreamTest::ReceiverInfo::status

Definition at line 214 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::CheckReceivers(), impala::DataStreamTest::ReadStream(), and impala::DataStreamTest::ReadStreamMerging().

shared_ptr<DataStreamRecvr> impala::DataStreamTest::ReceiverInfo::stream_recvr

Definition at line 213 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::ReadStream(), impala::DataStreamTest::ReadStreamMerging(), and impala::DataStreamTest::StartReceiver().

TPartitionType::type impala::DataStreamTest::ReceiverInfo::stream_type

Definition at line 208 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::CheckReceivers().

thread* impala::DataStreamTest::ReceiverInfo::thread_handle

Definition at line 212 of file data-stream-test.cc.

Referenced by impala::DataStreamTest::StartReceiver().

The documentation for this struct was generated from the following file: