Skip to content

Commit

Permalink
Removed refresh flag in flush command
Browse files Browse the repository at this point in the history
Elasticsearch v0.90.4
See elastic/elasticsearch@7cc48c8
  • Loading branch information
Fabien Pennequin committed Mar 7, 2014
1 parent 9efdd0b commit a781fed
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions src/main/scala/scalastic/elasticsearch/IndexCrud.scala
Original file line number Diff line number Diff line change
Expand Up @@ -214,22 +214,18 @@ trait Flush {

def flush(
indices: Iterable[String] = Nil,
full: Option[Boolean] = None,
refresh: Option[Boolean] = None) = flush_send(indices, full, refresh).actionGet
full: Option[Boolean] = None) = flush_send(indices, full).actionGet

def flush_send(
indices: Iterable[String] = Nil,
full: Option[Boolean] = None,
refresh: Option[Boolean] = None) = flush_prepare(indices, full, refresh).execute
full: Option[Boolean] = None) = flush_prepare(indices, full).execute

def flush_prepare(
indices: Iterable[String] = Nil,
full: Option[Boolean] = None,
refresh: Option[Boolean] = None) = {
full: Option[Boolean] = None) = {
/* method body */
val request = client.admin.indices.prepareFlush(indices.toArray: _*)
full foreach { request.setFull(_) }
// refresh foreach { request.setRefresh(_) }
request
}
}
Expand Down

0 comments on commit a781fed

Please sign in to comment.