streaming_bulk for iterative consumption of the input
bulk_index -> bulk
callback expand_action to transform input into action/data pairs
support for non-index actions through _op_type key
ES doesn't guarantee that refresh will wait for cluster state
propagation and thus the type might not exist right after the index
being created during the bulk load. Just check the documents instead.