Index

A

add_server() (my_application.stream_server.StreamServer method)

allowed_file() (in module my_application.views) authorized() (in module my_application.views)

B

BaselineToMongo (class in my_application.repositories.BaselineToMongo)

BaseRepository (class in my_application.repositories.CompetitionRepository) batch_size (my_application.repositories.CompetitionRepository.Competition attribute)

C

check_password() (my_application.repositories.CompetitionRepository.User method) check_subscription() (in module my_application.views) (my_application.repositories.CompetitionRepository.SubscriptionRepository method) chunker() (my_application.producer.CompetitionProducer static method) classification() (my_application.repositories.BaselineToMongo.BaselineToMongo static method) cleanup() (my_application.repositories.CompetitionRepository.BaseRepository method) client (my_application.repository.MongoRepository attribute) code (my_application.repositories.CompetitionRepository.Competition attribute) code_generator() (in module my_application.views) Competition (class in my_application.repositories.CompetitionRepository) competition (my_application.repositories.CompetitionRepository.Subscription attribute) competition_id (my_application.repositories.CompetitionRepository.Competition attribute) (my_application.repositories.CompetitionRepository.Subscription attribute) CompetitionProducer (class in my_application.producer)

CompetitionRepository (class in my_application.repositories.CompetitionRepository) competitions (my_application.repositories.CompetitionRepository.Datastream attribute) competitions() (in module my_application.views) confirm_email() (in module my_application.views) confirm_token() (in module my_application.views) confirm_user() (my_application.repositories.CompetitionRepository.UserRepository method) confirmed (my_application.repositories.CompetitionRepository.User attribute) confirmed_on (my_application.repositories.CompetitionRepository.User attribute) consumer (my_application.repositories.BaselineToMongo.BaselineToMongo attribute) (my_application.repositories.KafkaToMongo.ConsumerToMongo attribute) ConsumerToMongo (class in my_application.repositories.KafkaToMongo) create_collection() (my_application.repository.MongoRepository method) create_competition() (my_application.producer.CompetitionProducer method) create_database() (my_application.repository.MongoRepository method)

D

daemon (my_application.consumer.ProducerToMongoSink attribute) (my_application.producer.CompetitionProducer attribute) Datastream (class in my_application.repositories.CompetitionRepository) datastream (my_application.repositories.CompetitionRepository.Competition attribute) datastream_id (my_application.repositories.CompetitionRepository.Competition attribute) (my_application.repositories.CompetitionRepository.Datastream attribute) DataStreamerServicer (class in my_application.consumer) DatastreamRepository (class in my_application.repositories.CompetitionRepository) decode_auth_token() (in module my_application.auth)

decode_subscription_token() (in module my_application.subscription_auth) delete_many() (my_application.repositories.CompetitionRepository.UserRepository method) delete_one() (my_application.repositories.CompetitionRepository.BaseRepository method) delete_subscription() (in module my_application.views) delete_users() (in module my_application.views) description (my_application.repositories.CompetitionRepository.Competition attribute) (my_application.repositories.CompetitionRepository.Datastream attribute) download_data() (in module my_application.views) download_proto_file() (in module my_application.views)

E

email (my_application.repositories.CompetitionRepository.User attribute) encode_auth_token() (in module my_application.auth)

encode_subscription_token() (in module my_application.subscription_auth) end_date (my_application.repositories.CompetitionRepository.Competition attribute) evaluate() (in module my_application.sparkEvaluator)

F

file_path (my_application.repositories.CompetitionRepository.Competition attribute) (my_application.repositories.CompetitionRepository.Datastream attribute)

first_name (my_application.repositories.CompetitionRepository.User attribute)

G

generate_confirmation_token() (in module my_application.views) get_all_competitions() (my_application.repositories.CompetitionRepository.CompetitionRepository method) get_all_datastreams() (my_application.repositories.CompetitionRepository.DatastreamRepository method) get_all_users() (my_application.repositories.CompetitionRepository.UserRepository method) get_auth_token() (in module my_application.auth) get_competition_by_code() (my_application.repositories.CompetitionRepository.CompetitionRepository method) get_competition_by_id() (my_application.repositories.CompetitionRepository.CompetitionRepository method) get_competition_data_records() (my_application.repository.MongoRepository method) get_competition_evaluation_measure() (in module my_application.views) get_competition_evaluation_measures() (my_application.repository.MongoRepository method) get_competition_golden_standard() (in module my_application.views) get_competition_info() (in module my_application.views) get_competition_stream() (in module my_application.views) get_competition_subscribers() (my_application.repositories.CompetitionRepository.SubscriptionRepository method) get_competitions_by_user() (in module my_application.views) (my_application.repositories.CompetitionRepository.CompetitionRepository method)

get_datastream_by_id() (my_application.repositories.CompetitionRepository.DatastreamRepository method) get_datastream_info() (in module my_application.views) get_datastreams() (in module my_application.views) get_file_extension() (in module my_application.views) get_last_predictions_by_user() (my_application.repository.MongoRepository method) get_leaderboard_by_competition() (in module my_application.views) get_messages() (in module my_application.views) get_results_by_user() (my_application.repository.MongoRepository method) get_secret_key() (in module my_application.views) get_standard_evaluation_measures() (in module my_application.views) (my_application.repository.MongoRepository method) get_subscription() (my_application.repositories.CompetitionRepository.SubscriptionRepository method) get_subscription_token() (in module my_application.subscription_auth) get_user_by_email() (my_application.repositories.CompetitionRepository.UserRepository method) get_user_by_id() (my_application.repositories.CompetitionRepository.UserRepository method) get_users() (in module my_application.views) get_users_ranking_by_field_by_measure() (my_application.repository.MongoRepository method)

I

index() (in module my_application.views) initial_batch_size (my_application.repositories.CompetitionRepository.Competition attribute) initial_training_time (my_application.repositories.CompetitionRepository.Competition attribute) insert_document() (my_application.repository.MongoRepository method)

insert_many() (my_application.repositories.CompetitionRepository.BaseRepository method) insert_one() (my_application.repositories.CompetitionRepository.BaseRepository method) insert_standard_measures() (my_application.repository.MongoRepository method) instance (my_application.repositories.CompetitionRepository.BaseRepository attribute) is_not_empty() (my_application.producer.CompetitionProducer static method)

L

last_name (my_application.repositories.CompetitionRepository.User attribute)

login() (in module my_application.views)

M

main() (my_application.producer.CompetitionProducer method) me() (in module my_application.views) mongo_repository (my_application.repositories.BaselineToMongo.BaselineToMongo attribute) (my_application.repositories.KafkaToMongo.ConsumerToMongo attribute) MongoRepository (class in my_application.repository) my_application (module) my_application.auth (module) my_application.consumer (module) my_application.producer (module)

my_application.repositories (module) my_application.repositories.BaselineToMongo (module) my_application.repositories.CompetitionRepository (module) my_application.repositories.KafkaToMongo (module) my_application.repository (module) my_application.sparkEvaluator (module) my_application.sparkToMongo (module) my_application.stream_server (module) my_application.subscription_auth (module) my_application.views (module)

N

name (my_application.repositories.CompetitionRepository.Competition attribute) (my_application.repositories.CompetitionRepository.Datastream attribute)

P

password_hash (my_application.repositories.CompetitionRepository.User attribute) predictions_time_interval (my_application.repositories.CompetitionRepository.Competition attribute) process_golden() (my_application.sparkToMongo.SparkToMongo method) process_measures() (my_application.sparkToMongo.SparkToMongo method)

process_predictions() (my_application.sparkToMongo.SparkToMongo method) producer (my_application.consumer.ProducerToMongoSink attribute) (my_application.producer.CompetitionProducer attribute) ProducerToMongoSink (class in my_application.consumer)

R

read_csv_file() (in module my_application.producer) receive_predictions() (in module my_application.consumer) register() (in module my_application.views)

regression() (my_application.repositories.BaselineToMongo.BaselineToMongo static method) results_by_user_by_competition() (in module my_application.views) role (my_application.repositories.CompetitionRepository.User attribute) run() (my_application.sparkToMongo.SparkToMongo method)

S

schedule_competition() (my_application.producer.Scheduler method) Scheduler (class in my_application.producer) SECRET_KEY (in module my_application.auth) send() (my_application.consumer.ProducerToMongoSink method) (my_application.producer.CompetitionProducer method) sendData() (my_application.consumer.DataStreamerServicer method) serialize() (my_application.repositories.CompetitionRepository.Competition method) (my_application.repositories.CompetitionRepository.Datastream method) (my_application.repositories.CompetitionRepository.User method) server (my_application.stream_server.StreamServer attribute)

set_competition_code() (my_application.repositories.CompetitionRepository.CompetitionRepository method) set_password() (my_application.repositories.CompetitionRepository.User method) SparkToMongo (class in my_application.sparkToMongo) start() (my_application.producer.Scheduler method) start_date (my_application.repositories.CompetitionRepository.Competition attribute) start_server() (my_application.stream_server.StreamServer method) StreamServer (class in my_application.stream_server) Subscription (class in my_application.repositories.CompetitionRepository) subscription_id (my_application.repositories.CompetitionRepository.Subscription attribute) SubscriptionRepository (class in my_application.repositories.CompetitionRepository) subscriptions() (in module my_application.views)

T

target_class (my_application.repositories.CompetitionRepository.Competition attribute) terminate() (in module my_application.producer)

test() (in module my_application.views) time_create (my_application.repositories.CompetitionRepository.Subscription attribute) time_interval (my_application.repositories.CompetitionRepository.Competition attribute)

U

User (class in my_application.repositories.CompetitionRepository) user (my_application.repositories.CompetitionRepository.Subscription attribute)

user_id (my_application.repositories.CompetitionRepository.Subscription attribute) (my_application.repositories.CompetitionRepository.User attribute) UserRepository (class in my_application.repositories.CompetitionRepository)

W

write() (my_application.repositories.BaselineToMongo.BaselineToMongo method) (my_application.repositories.KafkaToMongo.ConsumerToMongo method)