Skip to content

Commit

Permalink
modify code style
Browse files Browse the repository at this point in the history
  • Loading branch information
baishuo committed Apr 24, 2015
1 parent 78d9fa3 commit ae61ec4
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -68,9 +68,9 @@ private[hive] case class HiveFunctionWrapper(var functionClassName: String)

@transient
def deserializeObjectByKryo[T: ClassTag](
kryo: Kryo,
in: InputStream,
clazz: Class[_]): T = {
kryo: Kryo,
in: InputStream,
clazz: Class[_]): T = {
val inp = new Input(in)
val t: T = kryo.readObject(inp,clazz).asInstanceOf[T]
inp.close()
Expand All @@ -79,9 +79,9 @@ private[hive] case class HiveFunctionWrapper(var functionClassName: String)

@transient
def serializeObjectByKryo(
kryo: Kryo,
plan: Object,
out: OutputStream ) {
kryo: Kryo,
plan: Object,
out: OutputStream ) {
val output: Output = new Output(out)
kryo.writeObject(output, plan)
output.close()
Expand Down

0 comments on commit ae61ec4

Please sign in to comment.