Astn

package super.hacky.flink.logging

import java.util

import ch.qos.logback.classic.LoggerContext
import ch.qos.logback.classic.selector.ContextSelector
import ch.qos.logback.classic.util.ContextInitializer
import org.apache.flink.runtime.taskmanager.{Task, TaskManagerRuntimeInfo}
import org.json4s.native.JsonMethods
import org.json4s.{JObject, JString}

Astn

I'm trying to dig into serialization performance issues in my scala flink job. I'm seeing all of the TypeInformation logs coming out of the java TypeExtractor instead of the scala TypeExtractor. This makes me think my case class 'EventValue' and the scala Option types are not being serialized with their specialized serializers.

INFO  2016-11-07 19:44:30,604 [main] org.apache.flink.api.java.typeutils.TypeExtractor  - class org.apache.avro.generic.GenericData$Record is not a valid POJO type
INFO  2016-11-07 19:44:30,608 [main] org.apache.flink.api.java.typeutils.TypeExtractor  - class org.apache.avro.generic.GenericData$Record is not a valid POJO type
INFO  2016-11-07 19:44:30,610 [main] org.apache.flink.api.java.typeutils.TypeExtractor  - class org.apache.avro.generic.GenericData$Record is not a valid POJO type
INFO  2016-11-07 19:44:30,610 [main] org.apache.flink.api.java.typeutils.TypeExtractor  - class org.apache.avro.generic.GenericData$Record is not a valid POJO type
INFO  2016-11-07 19:44:30,669 [ma

Astn

import rx.lang.scala.Observable

object stuff {
  case class generatedObject(config:String)
  case class myInterface(name:String, config:String)
  val mymap0 = Map("eth0" -> myInterface("eth0" ,"on"),
                    "eth1" -> myInterface("eth1" ,"on"),
                    "wifi0" -> myInterface("wifi0" ,"on"),
                    "wifi0" -> myInterface("wifi0" ,"off"))

Astn

/**
 * Created by astn on 6/26/15.
 */
/** 
 * Created by astn on 6/25/15.
 */



object themain {
  def rows(inp: Array[Int]): Array[Set[Int]] = {
     def nextRow(p: Array[Int], r: Int): Set[Int] = {
       p.drop(r * 9).take(9).toSet  


Astn

/**
 * Created by astn on 6/25/15.
 */
object themain {

  def rows(inp: Array[Int]): Array[Set[Int]] = {
    def nextRow(p: Array[Int], r:Int) = p.drop(r*9).take(9).toSet

    (0 to 8).map(f=> nextRow(inp,f)).toArray
  }

Astn

// given you have four 8's and the operators +,-,*,/
// and you want to determine how to order the operators
// to end up with the result of 56
val inputs = Seq(8,8,8,8)

val allOps = List(
  ((a:Int,b:Int)=>a+b,"+"),
  ((a:Int,b:Int)=>a-b,"-"),
  ((a:Int,b:Int)=>a*b,"*"),
  ((a:Int,b:Int)=>a/b,"/"))

Astn

using Nest;
using Nest.SerializationExtensions;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

Astn

-Astn: Austin Harris
TmanSquarePants: Tyler Ellingson

Astn

# Get us out of a git directory if we are in one.
#while (( ls -Directory -Hidden -Filter ".git" | measure).Count -gt 0 ) { 
#        Write-Warning "Moving up a directory because a hidden .git folder was detected"
#        $loc = (Get-Location).Path
#        Write-Warning "Now at ${loc}"
#        cd .. 
#    }

## pull latest of configuration project
IF ((Test-Path .\configuration) -eq $false) {

Astn

function elevateme {
    # Get the ID and security principal of the current user account
    $myWindowsID=[System.Security.Principal.WindowsIdentity]::GetCurrent()
    $myWindowsPrincipal=new-object System.Security.Principal.WindowsPrincipal($myWindowsID)
  
    # Get the security principal for the Administrator role
    $adminRole=[System.Security.Principal.WindowsBuiltInRole]::Administrator
  
    # Check to see if we are currently running "as Administrator"
    if ($myWindowsPrincipal.IsInRole($adminRole))