com.google.appengine.tools.mapreduce.inputs

Class LogInputReader

java.lang.Object

com.google.appengine.tools.mapreduce.InputReader<com.google.appengine.api.log.RequestLogs>

com.google.appengine.tools.mapreduce.inputs.LogInputReader

All Implemented Interfaces:

Serializable

public final class LogInputReader
extends InputReader<com.google.appengine.api.log.RequestLogs>

Reads App Engine RequestLogs for a specified time range. Assumes that logs are uniformly distributed over the time range for reporting progress.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected com.google.appengine.api.log.LogQuery	shardLogQuery

Method Summary

Methods

Modifier and Type	Method and Description
void	beginShard() Performs setup at the beginning of the shard.
void	beginSlice() Prepare this slice for reading.
void	endSlice() Prepares the InputReader for serialization.
Double	getProgress() Determine the approximate progress for this shard assuming the RequestLogs are uniformly distributed across the entire time range.
com.google.appengine.api.log.RequestLogs	next() Retrieve the next RequestLog

Methods inherited from class com.google.appengine.tools.mapreduce.InputReader

close, endShard, estimateMemoryRequirement, getContext, open, setContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

shardLogQuery

protected final com.google.appengine.api.log.LogQuery shardLogQuery

Method Detail

beginShard

public void beginShard()

Description copied from class: InputReader

Performs setup at the beginning of the shard. This method is invoked before the first call to InputReader.beginSlice(). It will not be invoked again unless the shard restarts. When a shard is restarted, this method is invoked and the input should be read from the beginning.

Overrides:

beginShard in class InputReader<com.google.appengine.api.log.RequestLogs>

beginSlice

public void beginSlice()

Prepare this slice for reading. If this the first slice in the shard, then the shardStartTime will be used. However if the is not the first slice use the last time read (+1, since that timestamp was already read) as the starting point.

Overrides:

beginSlice in class InputReader<com.google.appengine.api.log.RequestLogs>

endSlice

public void endSlice()

Description copied from class: InputReader

Prepares the InputReader for serialization.

Overrides:

endSlice in class InputReader<com.google.appengine.api.log.RequestLogs>

next

public com.google.appengine.api.log.RequestLogs next()
                                              throws NoSuchElementException

Retrieve the next RequestLog

Specified by:

next in class InputReader<com.google.appengine.api.log.RequestLogs>

Throws:

NoSuchElementException

getProgress

public Double getProgress()

Determine the approximate progress for this shard assuming the RequestLogs are uniformly distributed across the entire time range.

Overrides:

getProgress in class InputReader<com.google.appengine.api.log.RequestLogs>