edmondop

import {ChartData} from "chart.js";
import {getDateOfISOWeek, getDateStringOfISOWeek, getWeekNumber} from "../../../commons/src";
import {addMonths, addWeeks, differenceInCalendarMonths, differenceInCalendarWeeks, isPast, isFuture, addDays} from 'date-fns';

export interface IMonthlyChartData {
    Invoicer__c?: string;
    Reviewed_Agreed_Payment_Date__c?: string;
    Agreed_Payment_Date__c?: string;
    year?: number;
    month?: number;

edmondop

1

2

3

4

5

edmondop

class SimpleJoin(streamsConfiguration:Map[String,AnyRef]){

  private val builder = new KStreamBuilder

  private val myStream = builder.stream[Integer,MyClass](Serdes.Integer(),myClassSerde, "mytopic")


  private val myTable: KTable[Integer, MyClass] = myStream.groupBy(new KeyValueMapper[Integer,MyClass,Integer] {
    override def apply(key  : Integer,

edmondop

object SchemaFor extends LowPrioritySchemaFor{

  implicit object ByteSchemaFor extends SchemaFor[Byte] {
    private val schema = SchemaBuilder.builder().intType()
    def apply(): org.apache.avro.Schema = schema
  }

  implicit object ShortSchemaFor extends SchemaFor[Short] {
    private val schema = SchemaBuilder.builder().intType()
    def apply(): org.apache.avro.Schema = schema

edmondop

class SkipSpaceClassesWithoutIdHibernateSpaceDataSource(@BeanProperty  val sessionFactory:SessionFactory) extends SpaceDataSource {

  protected final val logger: Logger = LoggerFactory.getLogger(getClass)

  import scala.collection.JavaConverters._


  lazy val managedEntries = sessionFactory.getAllClassMetadata.asScala.keySet

  lazy val initialLoadEntries = {