|
YPC
0.2.0
|


Classes | |
| struct | point_traits |
Public Types | |
| typedef ::hpda::internal::processor_with_input< InputObjType > | base |
| typedef loyd_kmeans_impl< InputObjType, PointFlag, DistanceType, ClassifiedID, InitialPointPicker > | self_type |
| typedef ::ff::util::type_of_nt< PointFlag >::type | point_type |
| typedef kmeans_traits< point_type, DistanceType >::mean_point | mean_point |
| typedef kmeans_traits< point_type, DistanceType >::average_distance | average_distance |
| typedef ntobject< ClassifiedID, mean_point, average_distance > | means_stream_output_type |
| typedef ::hpda::extractor::internal::raw_data_impl< means_stream_output_type > | means_stream_t |
| typedef ::hpda::extractor::internal::raw_data_impl< typename ::ff::util::append_type< InputObjType, ClassifiedID >::type > | data_with_cluster_stream_t |
Public Types inherited from hpda::output::internal::output_base< InputObjType > | |
| typedef ::hpda::internal::processor_with_input< InputObjType > | base |
Public Types inherited from hpda::internal::processor_with_input< InputObjType > | |
| typedef InputObjType | input_type |
Public Member Functions | |
| loyd_kmeans_impl (::hpda::internal::processor_with_output< InputObjType > *upper_stream, int k, DistanceType delta, int max_points=std::numeric_limits< int >::max()) | |
| virtual bool | process () |
| data_with_cluster_stream_t * | data_with_cluster_stream () |
| means_stream_t * | means_stream () |
Public Member Functions inherited from hpda::output::internal::output_base< InputObjType > | |
| output_base (::hpda::internal::processor_with_output< InputObjType > *upper_stream) | |
| InputObjType | input_value () const |
| virtual void | done_value () |
Public Member Functions inherited from hpda::internal::processor_with_input< InputObjType > | |
| processor_with_input (processor_with_output< InputObjType > *input) | |
| InputObjType | input_value () const |
| bool | has_input_value () const |
| void | consume_input_value () |
| void | change_upper_stream (processor_with_output< InputObjType > *input) |
Public Member Functions inherited from hpda::functor | |
| void | reset_done_value () |
| bool | has_value () const |
| engine * | get_engine () const |
| void | set_engine (engine *e) |
| void | add_predecessor (functor *pred) |
| const std::vector< functor * > | predecessors () const |
Public Attributes | |
| std::vector< InputObjType > | m_all_points |
Protected Attributes | |
| std::unique_ptr< data_with_cluster_stream_t > | m_cluster_stream |
| std::unique_ptr< means_stream_t > | m_means_stream |
| bool | m_calculate_flag |
| int | m_k |
| DistanceType | m_delta |
| int | m_max_points |
Protected Attributes inherited from hpda::internal::processor_with_input< InputObjType > | |
| internal::processor_with_output< InputObjType > * | m_upper_stream |
Protected Attributes inherited from hpda::functor | |
| bool | m_has_value |
| std::vector< functor * > | m_predecessors |
| engine * | m_engine |
| uint32_t | m_status |
1.8.17